c27d5ec756b5bc9c42e4b4185b6fb1c38c3273a5,opennms-services/src/main/java/org/opennms/netmgt/eventd/EventIpcManagerDefaultImpl.java,EventIpcManagerDefaultImpl,broadcastNow,#Event#,280

Before Change


     * Called by eventd to send an event to all interested listeners
     */
    public synchronized void broadcastNow(Event event) {
        Category log = ThreadCategory.getInstance(this.getClass());
        if (log.isDebugEnabled())
            log.debug("Event to be broadcasted: " + event.getUei());

        if (m_listeners.size() <= 0) {
            if (log.isDebugEnabled())
                log.debug("No listeners interested in all events");

        }

        // send to listeners interested in receiving all events
        for(EventListener listener : m_listeners) {

            ListenerThread listenerThr = m_listenerThreads.get(listener.getName());
            try {
                listenerThr.getQueue().add(event);
                if (log.isDebugEnabled())
                    log.debug("Queued event to listener: " + listener.getName());
            } catch (FifoQueueException fe) {
                log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
            } catch (InterruptedException ie) {
                log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
            }
        }

        // get event UEI
        String uei = event.getUei();
        if (uei == null) {
            return;
        }

        // send to listeners who are interested in this event uei
        //Loop to get partial wild card "directory" matches
        while (uei.length() > 0){
        List<EventListener> listenerList = m_ueiListeners.get(uei);
        if (listenerList != null) {
            for(EventListener listener : listenerList) {
                ListenerThread listenerThread = m_listenerThreads.get(listener.getName());
                try {
                    listenerThread.getQueue().add(event);
                    if (log.isDebugEnabled())
                        log.debug("Queued event "+uei+" to listener: " + listener.getName());
                } catch (FifoQueueException fe) {
                    log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
                } catch (InterruptedException ie) {
                    log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
                }
            }
        } else {
            if (log.isDebugEnabled())
                log.debug("No listener interested in event: " + uei);
        }
        //Try wild cards: Find / before last character
        int i = uei.lastIndexOf("/",uei.length()-2);

After Change


     * Called by eventd to send an event to all interested listeners
     */
    public synchronized void broadcastNow(Event event) {
        if (log().isDebugEnabled()) {
            log().debug("Event to be broadcasted: " + event.getUei());
        }

        if (m_listeners.size() <= 0) {
            if (log().isDebugEnabled()) {
                log().debug("No listeners interested in all events");
            }

        }

        // send to listeners interested in receiving all events
        for (EventListener listener : m_listeners) {
            ListenerThread listenerThr = m_listenerThreads.get(listener.getName());
            try {
                listenerThr.getQueue().add(event);
                if (log().isDebugEnabled()) {
                    log().debug("Queued event to listener: " + listener.getName());
                }
            } catch (FifoQueueException fe) {
                log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
            } catch (InterruptedException ie) {
                log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
            }
        }

        // get event UEI
        String uei = event.getUei();
        if (uei == null) {
            return;
        }

        // send to listeners who are interested in this event uei
        //Loop to get partial wild card "directory" matches
        while (uei.length() > 0) {
            List<EventListener> listenerList = m_ueiListeners.get(uei);
            if (listenerList != null) {
                for (EventListener listener : listenerList) {
                    ListenerThread listenerThread = m_listenerThreads.get(listener.getName());
                    try {
                        listenerThread.getQueue().add(event);
                        if (log().isDebugEnabled()) {
                            log().debug("Queued event "+uei+" to listener: " + listener.getName());
                        }
                    } catch (FifoQueueException fe) {
                        log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
                    } catch (InterruptedException ie) {
                        log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
                    }
                }
            } else {
                if (log().isDebugEnabled()) {
                    log().debug("No listener interested in event: " + uei);
                }
            }